package Key_Value类型

import org.apache.spark.{SparkConf, SparkContext}

object cogroup {
    /*
     作用：在类型为(K,V)和(K,W)的RDD上调用，返回一个相同key对应的所有元素对在一起的(K,(V,W))的RDD
     笛卡尔积操作，效率低
     可以不满足key相同
     */

    def main(args: Array[String]): Unit = {

        val config: SparkConf = new SparkConf().setMaster("local[*]").setAppName("")

        val sc = new SparkContext(config)

        val rdd = sc.parallelize(Array((1, "a"), (2, "b"), (3, "c")))

        val rdd1 = sc.parallelize(Array((1, 4), (2, 5), (3, 6), (4, 7)))

        rdd.cogroup(rdd1).collect().foreach(println)

    }

}
